package com.lecture.javamode.oberver.eventbus;

import java.util.concurrent.Executors;

public class EventBusTest {


    public static void main(String[] args) {
        EventBus eventBus = new AsyncEventBus(Executors.newFixedThreadPool(20));

        eventBus.registry(new YMsg());

        eventBus.post("消息内容");
    }
}
